640589c82b85a3efc1288ff4a3ffbb4cbb5c7d1a,portal-impl/test/unit/com/liferay/portal/cluster/ClusterExecutorImplTest.java,ClusterExecutorImplTest,testExecuteWithCallBack2,#,728

Before Change



			// TimeoutException

			ClusterRequest clusterRequest = ClusterRequest.createUnicastRequest(
				null, new AddressImpl(new MockAddress()));

			MockClusterResponseCallback mockClusterResponseCallback =
				new MockClusterResponseCallback();

After Change


		try {
			clusterExecutorImpl = getClusterExecutorImpl(false, false);

			String timestamp = String.valueOf(System.currentTimeMillis());

			MethodHandler methodHandler = new MethodHandler(
				testMethod1MethodKey, timestamp);

			Address address = clusterExecutorImpl.getLocalClusterNodeAddress();

			ClusterRequest clusterRequest = ClusterRequest.createUnicastRequest(
				methodHandler, address);

			MockClusterResponseCallback mockClusterResponseCallback =
				new MockClusterResponseCallback();

			clusterExecutorImpl.execute(
				clusterRequest, mockClusterResponseCallback, 1000,
				TimeUnit.MILLISECONDS);

			ClusterNodeResponses clusterNodeResponses =
				mockClusterResponseCallback.waitMessage();

			assertFutureClusterResponsesWithoutException(
				clusterNodeResponses, clusterRequest.getUuid(), timestamp,
				address);

			// TimeoutException

			clusterRequest = ClusterRequest.createUnicastRequest(
				null, new AddressImpl(new MockAddress()));

			clusterExecutorImpl.execute(
				clusterRequest, mockClusterResponseCallback, 1000,